package com.imooc.ecommerce.sink;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * 自定义物流信息接口器
 * @author zhangshao
 * @since 2023/12/15 23:31
 */
public interface LogisticsSink {
    /**
     * 输入信道名称
     */
    String INPUT = "logisticsInput";

    /**
     * 物流Sink  --> LogisticsInput
     */
    @Input(LogisticsSink.INPUT)
    SubscribableChannel logisticsInput();


}
